package com.mooc.dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import com.mooc.entity.FileMessage;
import com.mooc.fileServlet.JdbcUtil;


/**
 * 数据库连接类
 * @author fan
 * 2021年11月2日21:06:19
 */
public class FileDaoTest {
	//将文件大小、文件类型，原始文件名、创建时间、文件保存目录地址等元数据记 录至数据库中
	public void fileTodb(String uuid,int size,String type,String filename,String createTime,String directory){
		String sql="insert into fileMessage values(?,?,?,?,?)";
		Connection con =JdbcUtil.getCon();
		try {
			PreparedStatement pre = con.prepareStatement(sql);
			pre.setString(1, uuid);
			pre.setInt(2, size);
			pre.setString(3, type);
			pre.setString(4, filename);
			pre.setString(5, createTime);
			pre.setString(6, directory);
			pre.executeUpdate();
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}
	//通过UUID 查询到 filename,directory
		public FileMessage findFileByUUid(String uuid){
			String sql="select filename,directory from  fileMessage where uuid=? ";
			Connection con =JdbcUtil.getCon();
			ResultSet set=null;
			FileMessage message = null;
			try {
				PreparedStatement pre = con.prepareStatement(sql);
				pre.setString(1, uuid);
				set=pre.executeQuery();
				while(set.next()){
				 message = new FileMessage();
				 message.setFilename(set.getString("filename"));
				 message.setDirectory("directory");
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
			return message;
		}

}
